package com.pie4cloud.pie.bus.api.consumer.factory;

import lombok.Data;

import java.util.concurrent.ConcurrentHashMap;
@Data
public class KfkClientFactory {
	//public static   ConcurrentHashMap<String, IKfkaConsumer> services=new ConcurrentHashMap<>();

    public static   ConcurrentHashMap<String, Long> isStop=new ConcurrentHashMap<>();
}
